package com.cloud.lesson.service.imp;

import com.cloud.lesson.service.IMessageProvider;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Source;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.support.MessageBuilder;

import javax.annotation.Resource;
import java.util.UUID;

/**
 * @author: Mr.Lai
 * @createTime: 2021/01/13
 * @classNote:
 **/
//定义消息的推送管道
@EnableBinding(Source.class) //指信道channel 和 exchange绑定在一起
public class MessageProviderImp implements IMessageProvider {
    @Resource
    private MessageChannel output;  // 消息发送管道

    @Override
    public String send() {
        String serial = UUID.randomUUID().toString();
        output.send(MessageBuilder.withPayload(serial).build());
        System.out.println("*****serial:"+serial);
        return serial;
    }
}
